package main

import (
	"demo-RxGo/Creating_Observables"
	"fmt"
)

func main() {
	fmt.Println("Demo_Create ##################")
	//Creating_Observables.Demo_Create()
	fmt.Println("Demo_Defer ##################")
	//Creating_Observables.Demo_Defer()
	fmt.Println("Demo_FromChannel ##################")
	//Creating_Observables.Demo_FromChannel()
	fmt.Println("Demo_FromEventSource ##################")
	//Creating_Observables.Demo_FromEventSource()
	//Creating_Observables.Demo_FromEventSourceWithBackPressureStrategy()
	fmt.Println("Demo_Interval ##################")
	Creating_Observables.Demo_Interval()
}
